from celery import Celery
import os



# 1.celery 是一个即插即用的 异步任务  celery运行的时候需要使用django的setting文件
# 我们需要在celery运行的时候 去配置

#　第一种方式
# so.environ.setdefault('DJANGO_SETTINGS_MODULE','mall.settings')

# 第二种方式
if not os.getenv('DJANGO_SETTINGS_MODULE'):
    os.environ['DJANGO_SETTINGS_MODULE'] = 'mall.settings'

# 2.我们需要创建celery对象
# 第一个参数 main  习惯上设置 脚本名
app = Celery('celery_tasks')

# 3.设置中间人 broker
# 路径
app.config_from_object('celery_tasks.config')

# 4.celery 自动检测任务
# 列表中的元素 就是任务的包路径
app.autodiscover_tasks(['celery_tasks.sms','celery_tasks.email'])

# 5.worker
# 我们的worker其实是一条指令 这条指令需要在虚拟环境中执行

